package com.acoreful.acf2admin.commons.mq;

import org.apache.thrift.TBase;

/**
 *	消费者
 * @param <T>
 */
public interface MqConsumer<T extends TBase<?, ?>> {

	 void consume(T message) throws Exception;
}
